package net.flyinggroup.kafka.consumer;

import lombok.extern.slf4j.Slf4j;
import net.flyinggroup.kafka.payload.Student;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class KafkaConsumer {
    @KafkaListener(topics = "walker")
    public void consumeJsonMsg(Message<?> message) {
        log.info("Consuming message from walker topic:: {}", message);
    }
}
